import axios from "axios"
import http from "node:http"
import kafka from "node-rdkafka"


// for(let i=0;i<10;i++){
//     await new Promise((resolve)=>{
//         setTimeout(()=>{
//             resolve()
//         },2000)
//     })
//      axios.get("https://codeforces.com/profile/tourist?graphType=rated").then((res)=>{
//         // console.log(res.data)
//     }).catch(err=>{
//         console.log(err)
//     })
// }

var producer =new kafka.Producer({
    'metadata.broker.list':"localhost:9092"
})
producer.connect()

producer.on("ready",()=>{
    producer.produce(
        "cfReq",
        null,
        Buffer.from(JSON.stringify({
            requestType:"contest_info.upcoming"
        })),
        "test"
    )
    // producer.produce(
    //     "cfReq",
    //     null,
    //     Buffer.from(JSON.stringify({
    //         requestType:"contest_info.past"
    //     })),
    //     "test"
    // )
    // producer.produce(
    //     "cfReq",
    //     null,
    //     Buffer.from(JSON.stringify({
    //         requestType:"user_info",
    //         name:"tourist"
    //     })),
    //     "test"
    // )
    // producer.produce(
    //     "cfReq",
    //     null,
    //     Buffer.from(JSON.stringify({
    //         requestType:"user_submission",
    //         name:"tourist",
    //         contestId:"1718"
    //     })),
    //     "test"
    // )
    // producer.produce(
    //     "cfReq",
    //     null,
    //     Buffer.from(JSON.stringify({
    //         requestType:"user_contest_history",
    //         name:"tourist",
    //         contestId:"1718"
    //     })),
    //     "test"
    // )

})

producer.setPollInterval(100)


producer.on("event.error",(err)=>{
    console.log(err)
})